package com.haozhen.watermark;

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author haozhen
 * @email haozh@ync1.com
 * @date 2021/2/10  22:58
 */
public class WaterMarkDemo1 {

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStreamSource<String> localhost = env.socketTextStream("localhost", 9999);
        data.map(MapFunction<String, Tuple2<> >)
    }
}
